package com.example.mq.mqserver.core;

import com.example.mq.common.MqException;

import java.io.IOException;

//  使用函数式接口表示 消费的具体过程,可支持 lambda 表达式传参
//  函数式接口满足: 接口里面只有一个抽象方法,可以包含静态方法
@FunctionalInterface
public interface Consume {
    void handleDelivery(String consumerTag,BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
